package com.majun.base.mono;

import reactor.core.publisher.Mono;

public class MonoOperationsExample {
	public static void main(String[] args) {
		Mono<Integer> mono = Mono.just(10).map(i -> i * 2) // 映射到双倍
				.doOnNext(System.out::println) // 打印元素
				.flatMap(i -> Mono.just(i / 2)); // 扁平映射

		// 订阅Mono
//		mono.subscribe();
		mono.subscribe(System.err::println);
	}
}
